package com.dx.gate.queue;

//import org.springframework.kafka.annotation.KafkaListener;

/**
 * 处理下行消费组信息
 * 接受从pusher模块发送的消息
 *
 * @author xufeng
 * @since 13.04.2023
 */
public class DownMsgTransfer {


//    @KafkaListener(id = "consumer-id", topics = {"topic1", "topic1", "topic3"}, groupId = "group-id")
//    public void listen(ConsumerRecord<?, ?> record) {
//        Optional<?> kafkaMessage = Optional.ofNullable(record.value());
//        if (kafkaMessage.isPresent()) {
//            Object message = kafkaMessage.get();
//            String topic = record.topic();
//            log.info(">>>kafka>>> topic: {}, msg: {}", topic, message);
//        }
//    }

}
